package jms;

import javax.ejb.Stateless;
import javax.jms.*;
import javax.naming.*;

@Stateless
public class EnviarMensaje
{
public void enviarMensaje(String texto,String asunto, String destinos)
{
	try 
	{ 		//Conectarse a la Cola de mensajes
			Context ic = new InitialContext();
			ConnectionFactory cf = (ConnectionFactory)ic.lookup("java:/ConnectionFactory"); 
			Queue queue = (Queue)ic.lookup("queue/test"); 
			Connection  connection = cf.createConnection(); 
			Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
			MessageProducer publisher = session.createProducer(queue); connection.start();
			//preparar el mensaje
			MapMessage message = session.createMapMessage();			
		    message.setString("asunto", asunto);
			message.setString("texto", texto);
			message.setString("destinos", destinos);
		    //enviar el mensaje
			publisher.send(message);
	 } catch (Exception exc) 
	 { 
		 exc.printStackTrace(); 
	 } 
} 

	

}
